package com.bjpowernode.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

/*
 * sql脚本：
 * drop table if exists t_act;
 * create table t_act(
 *     actno int,
 *     balance double(7,2)
 * );
 * insert into t_act(actno,balance) values (111,20000);
 * insert into t_act(actno,balance) values (222,0);
 * commit;
 * select * from t_act;
 *
 *  重点三行代码？
 *      conn.setAutoCommit(false);
 *      conn.commit();
 *      conn.rollback();
 *
 * */

public class JDBCTest11 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement ps = null;
        try {
            // 1、注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 2、获取连接
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/bjpowernode", "root", "246810");
            //把自动提交机制设置为手动提交机制
            conn.setAutoCommit(false); //开启事务
            // 3、获取预编译的数据库操作对象
            String sql = "update t_act set balance = ? where actno = ?";
            ps = conn.prepareStatement(sql);

            // 第一次给占位符传值
            ps.setInt(1, 10000);
            ps.setDouble(2, 111);
            int count = ps.executeUpdate(); // 执行第一条UPDATE语句

            /*String str = null;
            str.split(",");*/

            // 重新给占位符传值
            ps.setInt(1, 10000);
            ps.setDouble(2, 222);
            count += ps.executeUpdate(); // 执行第二条UPDATE语句
            System.out.println(count == 2 ? "转账成功" : "转账失败");

            //执行到这说明上面的代码没有异常，可以手动提交事务
            conn.commit(); //提交事务
        } catch (Exception e) {
            //说明事务中可能出现异常了，需要把数据回滚
            if(conn != null){
                try {
                    conn.rollback(); //事务回滚
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }
            e.printStackTrace();
        } finally {
            // 6、释放资源
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}
